//package com.gosling.cloudspace.listener;
//
//import com.alibaba.fastjson.JSONObject;
//import com.gosling.cloudspace.common.entity.pojo.UserMessage;
//import ApiParamsTool;
//import DateTool;
//import com.gosling.cloudspace.mapper.UserMessageMapper;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
///**
// * 消息聊天界面,的消息处理
// *
// * @email 1793327033@qq.com
// * @classname RabbimtMQListener
// * @author: osc_lihonglin
// * @date: 2021/7/20 16:19
// */
//@Component
//public class RabbimtMQListener {
//   protected static final Logger logger = LoggerFactory.getLogger(RabbimtMQListener.class);
//   @Autowired
//   UserMessageMapper userMessageMapper;
//
//   @RabbitListener(queues = "bootQueueMessage")
//   public void onOrderMessage(Message message) {
//      byte[] messageBody = message.getBody();
//      String body = new String(messageBody);
//      logger.info("接收到的消息：" + body);
//      JSONObject jsonObject = JSONObject.parseObject(body);
//      Object userId = jsonObject.get("userId");
//      Object senderId = jsonObject.get("senderId");
//      Object content = jsonObject.get("content");
//      Object image = jsonObject.get("image");
//      Object createTime = jsonObject.get("createTime");
//      if (ApiParamsTool.isEmpty(senderId, userId, content, image, createTime)) {
//         return;
//      }
//      UserMessage userMessage = new UserMessage();
//      userMessage.setUserId(Integer.parseInt(userId.toString()));
//      userMessage.setSenderId(Integer.parseInt(senderId.toString()));
//      userMessage.setContent(content.toString());
//      userMessage.setCreateTime(DateTool.dateAtWillFormat(createTime.toString()));
//      userMessage.setImage(image.toString());
//      try {
//         userMessageMapper.insert(userMessage);
//      } catch (Exception e) {
//         logger.error("消息保存失败");
//         e.printStackTrace();
//         return;
//      }
//      logger.info("MQ接受消息并保存成功！");
//   }
//}
